package com.lyb._02_work_queue;

import com.lyb.utlis.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

// 消息发送者
public class Send {

    // 队列的名字
    public static final String NAME_QUEUE_HELLOWORLD = "name_queue_helloworld";

    public static void main(String[] args) throws Exception {
        // 通过连接工具创建链接对象
        Connection connection = ConnectionUtil.getConnection();
        // 创建通道
        Channel channel = connection.createChannel();
        // 创建队列             队列名
        channel.queueDeclare(NAME_QUEUE_HELLOWORLD,true,false,false,null);
        // 消息内容
        String message = "有缘势必能有果、相守无缘终为陌";
        // 交换机(默认)           队列名(routingkey)        属性参数            消息内容
        channel.basicPublish("",NAME_QUEUE_HELLOWORLD,null,message.getBytes());
        System.out.println("消息发送完毕："+message);
    }

}
